//
// Created by linyongzhi on 2023/12/12.
//

#ifndef PC_SDK_DEMO_CPHBUFFERQUEUE_H
#define PC_SDK_DEMO_CPHBUFFERQUEUE_H

#include <mutex>
#include <queue>
#include "CPHBuffer.h"

class CPHBufferQueue {

public:
    CPHBufferQueue();

    virtual ~CPHBufferQueue();

    bool IsQueueEmpty();
    CPHBuffer GetNextData();
    void pushData(CPHBuffer &bufferData);

private:
    std::mutex mutex;
    std::queue<CPHBuffer> bufferQueue;
};


#endif //PC_SDK_DEMO_CPHBUFFERQUEUE_H
